/***************************************************************************
 * Copyright (C) 2010
 * by Dimok
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 ***************************************************************************/
#include <unistd.h>
#include <malloc.h>
#include "OggDecoder.hpp"

extern "C"  int ogg_read(void * punt, int bytes, int blocks, int *f)
{
	return ((CFile *) f)->read((u8 *) punt, bytes*blocks);
}

extern "C" int ogg_seek(int *f, ogg_int64_t offset, int mode)
{
	return ((CFile *) f)->seek((u64) offset, mode);
}

extern "C" int ogg_close(int *f)
{
	((CFile *) f)->close();
	return 0;
}

extern "C" long ogg_tell(int *f)
{
	return (long) ((CFile *) f)->tell();
}

static ov_callbacks callbacks = {
	(size_t (*)(void *, size_t, size_t, void *))  ogg_read,
	(int (*)(void *, ogg_int64_t, int))		   ogg_seek,
	(int (*)(void *))							 ogg_close,
	(long (*)(void *))							ogg_tell
};

OggDecoder::OggDecoder(const char * filepath)
	: SoundDecoder(filepath)
{
	SoundType = SOUND_OGG;

	if(!file_fd)
		return;

	OpenFile();
}

OggDecoder::OggDecoder(const u8 * snd, int len)
	: SoundDecoder(snd, len)
{
	SoundType = SOUND_OGG;

	if(!file_fd)
		return;

	OpenFile();
}

OggDecoder::~OggDecoder()
{
	ExitRequested = true;
	while(Decoding)
		usleep(100);

	if(file_fd)
		ov_clear(&ogg_file);
}

void OggDecoder::OpenFile()
{
	if (ov_open_callbacks(file_fd, &ogg_file, NULL, 0, callbacks) < 0)
	{
		delete file_fd;
		file_fd = NULL;
		return;
	}

	ogg_info = ov_info(&ogg_file, -1);
	if(!ogg_info)
	{
		ov_clear(&ogg_file);
		delete file_fd;
		file_fd = NULL;
		return;
	}
	
	Format = ((ogg_info->channels == 2) ? VOICE_STEREO_16BIT : VOICE_MONO_16BIT);
	SampleRate = ogg_info->rate;
	
	Decode();
}

int OggDecoder::Rewind()
{
	if(!file_fd)
		return -1;

	int ret = ov_time_seek(&ogg_file, 0);
	CurPos = 0;
	EndOfFile = false;

	return ret;
}

int OggDecoder::Read(u8 * buffer, int buffer_size, int pos UNUSED)
{
	if(!file_fd)
		return -1;

	int bitstream = 0;

	int read = ov_read(&ogg_file, (char *) buffer, buffer_size, &bitstream);

	if(read > 0)
		CurPos += read;

	return read;
}
